const MongoClient = require('mongodb').MongoClient
const ObjectID = require('mongodb').ObjectID;

const Config = require('./config.js');

class Db {
    static getInstance() { //单例      多次实例化实例不共享的问题
        if (!Db.instance) {
            Db.instance = new Db();
        }
        return Db.instance;
    }

    constructor() {
        this.dbClient = ''; //属性  放db对象
        this.connect(); //实例化的时候就连接数据库
    }

    connect() { //连接数据库
        return new Promise((resolve, reject) => {
            if (!this.dbClient) { //解决数据库多次连接的问题
                MongoClient.connect(Config.dbUrl, {
                    useNewUrlParser: true
                }, (err, client) => {
                    if (err) {
                        reject(err)
                    } else {
                        this.dbClient = client.db(Config.dbName); /*获取db对象*/
                        resolve(this.dbClient);
                    }
                })
            } else {
                resolve(this.dbClient);
            }
        })
    }

    find(collectionName, json) { //查询数据
        return new Promise((resolve, reject) => {
            this.connect().then((db) => {
                var result = db.collection(collectionName).find(json);
                result.toArray(function (err, docs) {
                    if (err) {
                        reject(err);
                    } else {
                        resolve(docs);
                    }
                })
            })
        })
    }

    insert(collectionName, json) { //增加数据
        return new Promise((resolve, reject) => {
            this.connect().then((db) => {
                db.collection(collectionName).insertOne(json, function (err, result) {
                    if (err) {
                        reject(err);
                    } else {
                        resolve(result);
                    }
                })
            })
        })
    }

    update(collectionName, json1, json2) { //更新数据
        return new Promise((resolve, reject) => {
            this.connect().then((db) => {
                db.collection(collectionName).updateOne(json1, {
                    $set: json2
                }, function (err, result) {
                    if (err) {
                        reject(err);
                    } else {
                        resolve(result);
                    }
                })
            })
        })
    }

    remove(collectionName, json) { //删除数据
        return new Promise((resolve, reject) => {
            this.connect().then((db) => {
                db.collection(collectionName).removeOne(json, function (err, result) {
                    if (err) {
                        reject(err);
                    } else {
                        resolve(result);
                    }
                })
            })
        })
    }

    getObjectID(id){        //MongoDB里面查询_id,把字符串改为对象
        return new ObjectID(id);
    }
}

/* console.time('start')
var myDb = Db.getInstance();
myDb.find('user', {}).then(function (data) {
    console.log(data)
    console.timeEnd('start')
})

setTimeout(function(){
    console.time('start1')
    myDb.find('user', {}).then(function (data) {
        console.log(data)
        console.timeEnd('start1')
    })
},3000) */

module.exports = Db.getInstance();